package com.catmiao.spark.test

/**
 * @title: SubTask
 * @projectName spark_study
 * @description: TODO
 * @author ChengMiao
 * @date 2024/1/12 16:20
 */
class SubTask extends Serializable {

  var datas : List[Int] = _

  var logic: (Int) => Int = _

  def comp() = {
    datas.map(logic)
  }

}
